package com.wedata.RabbitMq;

import java.io.IOException;
import java.util.concurrent.TimeoutException;

public class 生产者 {

    public static void main(String[] args) throws IOException, TimeoutException {
        MQUtil.producer("10000");
    }

    public void 普通消息() throws IOException, TimeoutException {
        for(int i=0;i<10;i++){
            MQUtil.producer(i);
        }
    }
}
